-
Notifications
You must be signed in to change notification settings - Fork 90
feat: DH-21100: Allow Formula in rollups #7579
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: main
Are you sure you want to change the base?
Conversation
…roupByReaggregateOperator.java Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
…ces/aggregate/AggregateColumnSource.java Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
…roupByOperator.java Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
…roupByReaggregateOperator.java Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
| return newOperator; | ||
| } | ||
|
|
||
| GroupByReaggregateOperator ensureGroupByReaggregateOperator(final QueryTable table, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
No Javadoc for this. Not required, but ensureGroupByOperator() above is documented
| @@ -878,8 +1039,9 @@ public void visit(@NotNull final AggSpecFirst first) { | |||
| @Override | |||
| public void visit(@NotNull final AggSpecFormula formula) { | |||
| unsupportedForBlinkTables("Formula"); | |||
| // TODO: re-use shared groupBy operators (https://github.com/deephaven/deephaven-core/issues/6363) | |||
| final GroupByChunkedOperator groupByChunkedOperator = new GroupByChunkedOperator(table, false, null, | |||
| // Note: we do not attempt to reuse the groupBy operator for the deprecated "each" formula, we only reuse | |||
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should we close #6363?
| if (!(source instanceof AggregateColumnSource)) { | ||
| throw new IllegalStateException("Expect to reaggregate AggregateColumnSources for a group operation."); | ||
| } | ||
| @SuppressWarnings("rawtypes") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This looks odd, used to seeing comment-style inside a code block instead of a decorator. Is this correct usage?
| return newOperator; | ||
| } | ||
|
|
||
| @NonNull |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
No description provided.